package com.example.rabbitmq.demo3_pub_and_returned_confirm;

import com.rabbitmq.client.ConfirmListener;

import java.io.IOException;

/**
 * @Author songyahui
 * @Date 2023/7/14 10:47
 * @Description
 */
public class ConfirmListenerImpl implements ConfirmListener {
    @Override
    public void handleAck(long deliveryTag, boolean multiple) throws IOException {
        System.out.println("handleAck：消息处理成功,deliveryTag:" + deliveryTag + ", isMultiple:" + multiple);
    }

    @Override
    public void handleNack(long deliveryTag, boolean multiple) throws IOException {
        System.out.println("handleNack：消息处理失败,deliveryTag:"+deliveryTag);

    }
}
